package com.dddframework.mq.core;

import com.dddframework.core.contract.MQEvent;

public interface MQEventStorer<T extends MQEvent> {

    /**
     * 消息持久化
     */
    void store(T mqEvent);
}